package com.zc.im.connector.consumer;

import com.dyuproject.protostuff.Message;
import com.zc.im.common.msg.AbstractMsg;
import com.zc.im.common.msg.Msg;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * Project：im
 * Date：2022/4/24
 * Time：11:24
 * Description：消息消费者
 *
 * @author Challen.Zhang
 * @version 1.0
 */
@Slf4j
@Component
@RocketMQMessageListener(topic = "#{imConfigProperties.mqConfig.messageTopic}",
        consumerGroup = "#{imConfigProperties.mqConfig.group}",
        selectorExpression = "#{ipUtil.addressAndPort}")
public class MessageConsumer implements RocketMQListener<Msg> {
    @Override
    public void onMessage(Msg msg) {

    }
}
